# -*- encoding: utf-8 -*-

from plugin.task.redis_consumer import RedisConsumerThreadPool
from plugin.utils.process_utils import GracefulKiller


if __name__ == '__main__':
    graceful_killer = GracefulKiller()
    RedisConsumerThreadPool().start(graceful_killer, max_retry=10)
